src/lib/providers/googleVertex.ts (3)

423-446: Normalize error matching and honor HTTP status codes.

Use a lowercased message and check optional status fields to make detection robust. Also include ETIMEDOUT/timeout and common gateway phrases.

Apply this diff:

-    if (
-      message.includes("ECONNRESET") ||
-      message.includes("ENOTFOUND") ||
-      message.includes("ECONNREFUSED") ||
-      message.includes("network") ||
-      message.includes("connection")
-    ) {
+    const lowerMessage = message.toLowerCase();
+    const status =
+      (errorRecord as { status?: number })?.status ??
+      (errorRecord as { response?: { status?: number } })?.response?.status;
+
+    if (
+      lowerMessage.includes("econnreset") ||
+      lowerMessage.includes("enotfound") ||
+      lowerMessage.includes("econnrefused") ||
+      lowerMessage.includes("etimedout") ||
+      lowerMessage.includes("network") ||
+      lowerMessage.includes("connection") ||
+      lowerMessage.includes("timeout")
+    ) {
       return new Error(
         "Google Vertex AI API connection error. Please check your internet connection and try again.",
       );
     }
 
-    if (
-      message.includes("500") ||
-      message.includes("502") ||
-      message.includes("503") ||
-      message.includes("504") ||
-      message.includes("server error")
-    ) {
+    if (
+      status === 500 ||
+      status === 502 ||
+      status === 503 ||
+      status === 504 ||
+      lowerMessage.includes("server error") ||
+      lowerMessage.includes("bad gateway") ||
+      lowerMessage.includes("gateway timeout")
+    ) {
       return new Error(
         "Google Vertex AI API server error. Please try again in a few moments.",
       );
     }

---

177-183: Doc nit: comment says WeakMap but a Map is used.

Align the comment with the implementation to avoid confusion.

Apply this diff:

-  // Memory-managed cache for model configuration lookups to avoid repeated calls
-  // Uses WeakMap for automatic cleanup and bounded LRU for recently used models
+  // Memory-managed cache for model configuration lookups to avoid repeated calls
+  // Uses a bounded LRU strategy with Map for recently used models

---

418-422: Optional: lowercase once at source.

For consistency with other providers and tests, compute a lowercase variant once and reuse in all checks.

src/lib/providers/openAI.ts (2)

97-131: Harden error detection: lowercase matching and status checks.

Normalize the message and include HTTP status where available for rate limit, connection, and server errors.

Apply this diff:

-    if (
-      message.includes("rate limit") ||
-      message.includes("rate_limit_exceeded") ||
-      message.includes("429")
-    ) {
+    const lower = message.toLowerCase();
+    const status =
+      (errorObj as { status?: number })?.status ??
+      (errorObj as { response?: { status?: number } })?.response?.status;
+
+    if (
+      status === 429 ||
+      lower.includes("rate limit") ||
+      lower.includes("rate_limit_exceeded") ||
+      lower.includes("429")
+    ) {
       return new Error("OpenAI rate limit exceeded. Please try again later.");
     }
 
-    // Handle connection errors
-    if (
-      message.includes("ECONNRESET") ||
-      message.includes("ENOTFOUND") ||
-      message.includes("ECONNREFUSED") ||
-      message.includes("network") ||
-      message.includes("connection")
-    ) {
+    // Handle connection errors
+    if (
+      lower.includes("econnreset") ||
+      lower.includes("enotfound") ||
+      lower.includes("econnrefused") ||
+      lower.includes("etimedout") ||
+      lower.includes("network") ||
+      lower.includes("connection") ||
+      lower.includes("timeout")
+    ) {
       return new Error(
         "OpenAI API connection error. Please check your internet connection and try again.",
       );
     }
 
-    // Handle server errors
-    if (
-      message.includes("500") ||
-      message.includes("502") ||
-      message.includes("503") ||
-      message.includes("504") ||
-      message.includes("server error")
-    ) {
+    // Handle server errors
+    if (
+      status === 500 ||
+      status === 502 ||
+      status === 503 ||
+      status === 504 ||
+      lower.includes("server error") ||
+      lower.includes("bad gateway") ||
+      lower.includes("gateway timeout")
+    ) {
       return new Error(
         "OpenAI API server error. Please try again in a few moments.",
       );
     }
 
-    return new Error(`OpenAI Error: ${message}`);
+    return new Error(`OpenAI Error: ${message}`);

---

82-87: Optional: precompute lowercase message
Compute const lowerMessage = message.toLowerCase() once after deriving message and use lowerMessage.includes(…) in the subsequent error-handling checks.

src/lib/providers/mistral.ts (1)

173-212: Harden error detection: lowercase matching and status checks.

Normalize the message and include HTTP status where available; also lower-case the model-not-found check.

Apply this diff:

-    if (
-      message.includes("rate limit") ||
-      message.includes("rate_limit_exceeded") ||
-      message.includes("429")
-    ) {
+    const lower = message.toLowerCase();
+    const status =
+      (errorRecord as { status?: number })?.status ??
+      (errorRecord as { response?: { status?: number } })?.response?.status;
+
+    if (
+      status === 429 ||
+      lower.includes("rate limit") ||
+      lower.includes("rate_limit_exceeded") ||
+      lower.includes("429")
+    ) {
       return new Error("Mistral rate limit exceeded. Please try again later.");
     }
 
-    if (
-      message.includes("ECONNRESET") ||
-      message.includes("ENOTFOUND") ||
-      message.includes("ECONNREFUSED") ||
-      message.includes("network") ||
-      message.includes("connection")
-    ) {
+    if (
+      lower.includes("econnreset") ||
+      lower.includes("enotfound") ||
+      lower.includes("econnrefused") ||
+      lower.includes("etimedout") ||
+      lower.includes("network") ||
+      lower.includes("connection") ||
+      lower.includes("timeout")
+    ) {
       return new Error(
         "Mistral API connection error. Please check your internet connection and try again.",
       );
     }
 
-    if (
-      message.includes("500") ||
-      message.includes("502") ||
-      message.includes("503") ||
-      message.includes("504") ||
-      message.includes("server error")
-    ) {
+    if (
+      status === 500 ||
+      status === 502 ||
+      status === 503 ||
+      status === 504 ||
+      lower.includes("server error") ||
+      lower.includes("bad gateway") ||
+      lower.includes("gateway timeout")
+    ) {
       return new Error(
         "Mistral API server error. Please try again in a few moments.",
       );
     }
 
-    if (message.includes("model") && message.includes("not found")) {
+    if (lower.includes("model") && lower.includes("not found")) {
       return new Error(
         `Mistral model '${this.modelName}' not found.\n\nSuggestions:\n1. Check model name spelling\n2. Ensure you have access to the model`,
       );
     }
 
-    return new Error(`Mistral Error: ${message}`);
+    return new Error(`Mistral Error: ${message}`);

src/lib/providers/amazonBedrock.ts (2)

163-196: Harden error detection: lowercase matching and status checks (AWS often sets $metadata.httpStatusCode).

Normalize the message and read status from multiple potential locations.

Apply this diff:

-    if (
-      errorMessage.includes("rate limit") ||
-      errorMessage.includes("throttling") ||
-      errorMessage.includes("429")
-    ) {
+    const lower = errorMessage.toLowerCase();
+    const status =
+      (error as { status?: number })?.status ??
+      (error as { $metadata?: { httpStatusCode?: number } })?.$metadata?.httpStatusCode ??
+      (error as { response?: { status?: number } })?.response?.status;
+
+    if (
+      status === 429 ||
+      lower.includes("rate limit") ||
+      lower.includes("throttling") ||
+      lower.includes("too many requests") ||
+      lower.includes("429")
+    ) {
       return new Error(
         "Amazon Bedrock rate limit exceeded. Please try again later.",
       );
     }
 
-    if (
-      errorMessage.includes("ECONNRESET") ||
-      errorMessage.includes("ENOTFOUND") ||
-      errorMessage.includes("ECONNREFUSED") ||
-      errorMessage.includes("network") ||
-      errorMessage.includes("connection")
-    ) {
+    if (
+      lower.includes("econnreset") ||
+      lower.includes("enotfound") ||
+      lower.includes("econnrefused") ||
+      lower.includes("etimedout") ||
+      lower.includes("network") ||
+      lower.includes("connection") ||
+      lower.includes("timeout")
+    ) {
       return new Error(
         "Amazon Bedrock API connection error. Please check your internet connection and try again.",
       );
     }
 
-    if (
-      errorMessage.includes("500") ||
-      errorMessage.includes("502") ||
-      errorMessage.includes("503") ||
-      errorMessage.includes("504") ||
-      errorMessage.includes("server error")
-    ) {
+    if (
+      status === 500 ||
+      status === 502 ||
+      status === 503 ||
+      status === 504 ||
+      lower.includes("server error") ||
+      lower.includes("bad gateway") ||
+      lower.includes("gateway timeout")
+    ) {
       return new Error(
         "Amazon Bedrock API server error. Please try again in a few moments.",
       );
     }

---

122-138: Consistency: add timeout/abortSignal to Bedrock streaming like other providers.

Adopt the same timeout controller pattern to avoid hanging requests.

Apply this diff:

-    try {
-      this.validateStreamOptions(options);
+    try {
+      this.validateStreamOptions(options);
+      const timeout = this.getTimeout(options);
+      const timeoutController = createTimeoutController(
+        timeout,
+        this.providerName,
+        "stream",
+      );
 
       // Build message array from options
       const messages = buildMessagesArray(options);
 
-      const result = await streamText({
+      const result = await streamText({
         model: this.model,
         messages: messages,
         maxTokens: options.maxTokens || DEFAULT_MAX_TOKENS,
         temperature: options.temperature,
+        abortSignal: timeoutController?.controller.signal,
       });
 
+      timeoutController?.cleanup();

src/lib/providers/anthropic.ts (1)

88-140: Consolidate to lowercase message and include HTTP status checks.

Improves robustness and aligns with other providers.

Apply this diff:

-    const message =
-      typeof errorRecord?.message === "string"
-        ? errorRecord.message
-        : "Unknown error";
+    const message =
+      typeof errorRecord?.message === "string"
+        ? errorRecord.message
+        : "Unknown error";
+    const lowerMessage = message.toLowerCase();
+    const status =
+      (errorRecord as { status?: number })?.status ??
+      (errorRecord as { response?: { status?: number } })?.response?.status;
@@
-    if (
-      message.includes("API_KEY_INVALID") ||
-      message.includes("Invalid API key")
-    ) {
+    if (
+      lowerMessage.includes("api_key_invalid") ||
+      lowerMessage.includes("invalid api key")
+    ) {
       return new Error(
         "Invalid Anthropic API key. Please check your ANTHROPIC_API_KEY environment variable.",
       );
     }
@@
-    if (
-      message.includes("rate limit") ||
-      message.includes("too_many_requests") ||
-      message.includes("429")
-    ) {
+    if (
+      status === 429 ||
+      lowerMessage.includes("rate limit") ||
+      lowerMessage.includes("too_many_requests") ||
+      lowerMessage.includes("429")
+    ) {
       return new Error(
         "Anthropic rate limit exceeded. Please try again later.",
       );
     }
@@
-    if (
-      message.includes("ECONNRESET") ||
-      message.includes("ENOTFOUND") ||
-      message.includes("ECONNREFUSED") ||
-      message.includes("network") ||
-      message.includes("connection")
-    ) {
+    if (
+      lowerMessage.includes("econnreset") ||
+      lowerMessage.includes("enotfound") ||
+      lowerMessage.includes("econnrefused") ||
+      lowerMessage.includes("etimedout") ||
+      lowerMessage.includes("network") ||
+      lowerMessage.includes("connection") ||
+      lowerMessage.includes("timeout")
+    ) {
       return new Error(
         "Anthropic API connection error. Please check your internet connection and try again.",
       );
     }
@@
-    if (
-      message.includes("500") ||
-      message.includes("502") ||
-      message.includes("503") ||
-      message.includes("504") ||
-      message.includes("server error")
-    ) {
+    if (
+      status === 500 ||
+      status === 502 ||
+      status === 503 ||
+      status === 504 ||
+      lowerMessage.includes("server error") ||
+      lowerMessage.includes("bad gateway") ||
+      lowerMessage.includes("gateway timeout")
+    ) {
       return new Error(
         "Anthropic API server error. Please try again in a few moments.",
       );
     }
 
-    return new Error(`Anthropic Error: ${message}`);
+    return new Error(`Anthropic Error: ${message}`);

Configuration used: CodeRabbit UI

Review profile: CHILL

Plan: Pro

Learnt from: RajuSudhar
PR: juspay/neurolink#173
File: src/lib/index.ts:16-16
Timestamp: 2025-09-17T17:55:15.261Z
Learning: In src/lib/types/providers.ts, ProviderConfig was renamed to AIModelProviderConfig to deduplicate type names, as there was an existing ProviderConfig type that better suited the "ProviderConfig" name. This was an intentional breaking change for better type organization.

Learnt from: YasmeenOgo
PR: juspay/neurolink#145
File: src/lib/core/types.ts:0-0
Timestamp: 2025-09-02T13:50:42.770Z
Learning: The APIVersions enum in src/lib/core/types.ts now contains comprehensive API version constants for all major AI providers: Azure OpenAI (latest, stable, legacy), OpenAI (current, beta), Google AI (current, beta), and Anthropic (current). This centralization helps avoid API version drift across the codebase.